github.com/go-pg/pg/v10.Listener.db (field)
14 uses
github.com/go-pg/pg/v10 (current package)
db.go#L80: db: db,
listener.go#L33: db *DB
listener.go#L86: cn, err := ln.db.pool.NewConn(ctx)
listener.go#L91: if err := ln.db.initConn(ctx, cn); err != nil {
listener.go#L92: _ = ln.db.pool.CloseConn(cn)
listener.go#L101: _ = ln.db.pool.CloseConn(cn)
listener.go#L130: internal.Logger.Printf(ln.db.ctx, "pg: discarding bad listener connection: %s", reason)
listener.go#L133: err := ln.db.pool.CloseConn(ln.cn)
listener.go#L173: err := cn.WithWriter(ctx, ln.db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
listener.go#L175: if err := writeQueryMsg(wb, ln.db.fmter, "LISTEN ?", pgChan(channel)); err != nil {
listener.go#L206: err := cn.WithWriter(ctx, ln.db.opt.WriteTimeout, func(wb *pool.WriteBuffer) error {
listener.go#L208: if err := writeQueryMsg(wb, ln.db.fmter, "UNLISTEN ?", pgChan(channel)); err != nil {
listener.go#L275: ctx := ln.db.ctx
listener.go#L365: _, err := ln.db.Exec("NOTIFY ?", pgChan(gopgChannel))